package com.xiaoyilin.fast;

import org.apache.kafka.common.serialization.Deserializer;

import java.util.Map;

/**
 * 自定义反序列器
 *
 * org.apache.kafka.common.serialization.Deserializer
 *
 * 接口实现类
 * org.apache.kafka.common.serialization.ShortDeserializer
 *
 */
public class MyKafkaDeserializer implements Deserializer {

    @Override
    public void configure(Map map, boolean b) {

    }

    @Override
    public Object deserialize(String s, byte[] bytes) {
        return null;
    }

    @Override
    public void close() {

    }
}
